.NET Core 3.0 创建基于Consul的Configuration扩展组件

（给DotNet加星标，提升.Net技能）

转自：艾心❤

cnblogs.com/edison0621/p/10922281.html

写在前面

经过关于《.NET Core 3.0源码理解Configuration》的文章之后，本篇文章主要讨论如何扩展一个Configuration组件出来。

了解了Configuration的源码后，再去扩展一个组件就会比较简单，接下来我们将在.NET Core 3.0-preview5的基础上创建一个基于Consul的配置组件。

相信大家对Consul已经比较了解了，很多项目都会使用Consul作为配置中心，此处也不做其他阐述了，主要是讲一下，创建Consul配置扩展的一些思路。

使用Consul配置功能时，我们可以将信息转成JSON格式后再存储，那么我们在读取的时候，在体验上就像是从读取JSON文件中读取一样。

开发前的准备

初始化Consul

假设你已经安装并启动了Consul，我们打开Key/Value功能界面，创建两组配置选项出来，分别是commonservice和userservice，如下图所示

配置值采用JSON格式

实现思路

我们知道在Configuration整个的设计框架里，比较重要的类ConfigurationRoot，内部又有一个IConfigurationProvider集合属性，也就是说我们追加IConfigurationProvider实例最终也会被放到到该集合中，如下图所示

该项目中，我使用到了一个已经封装好的Consul(V0.7.2.6)类库，同时基于.NET Core关于Configuration的设计风格，做如下的框架设计

考虑到我会在该组件内部创建ConsulClient实例，所以对ConsulClient构造函数的一部分参数做了抽象提取，并添加到了IConsulConfigurationSource中，以增强该组件的灵活性。

之前说过，Consul中的配置信息是以JSON格式存储的，所以此处使用到了Microsoft.Extensions.Configuration.Json.JsonConfigurationFileParser，用以将JSON格式的信息转换为Configuration的通用格式Key/Value。

核心代码

IConsulConfigurationSource

/// <summary>
/// ConsulConfigurationSource
/// </summary>
public interface IConsulConfigurationSource : IConfigurationSource
{
    /// <summary>
    /// CancellationToken
    /// </summary>
    CancellationToken CancellationToken { get; }

    /// <summary>
    /// Consul构造函数实例，可自定义传入
    /// </summary>
    Action<ConsulClientConfiguration> ConsulClientConfiguration { get; set; }

    /// <summary>
    ///  Consul构造函数实例，可自定义传入
    /// </summary>
    Action<HttpClient> ConsulHttpClient { get; set; }

    /// <summary>
    ///  Consul构造函数实例，可自定义传入
    /// </summary>
    Action<HttpClientHandler> ConsulHttpClientHandler { get; set; }

    /// <summary>
    /// 服务名称
    /// </summary>
    string ServiceKey { get; }

    /// <summary>
    /// 可选项
    /// </summary>
    bool Optional { get; set; }

    /// <summary>
    /// Consul查询选项
    /// </summary>
    QueryOptions QueryOptions { get; set; }

    /// <summary>
    /// 重新加载延迟时间，单位是毫秒
    /// </summary>
    int ReloadDelay { get; set; }

    /// <summary>
    /// 是否在配置改变的时候重新加载
    /// </summary>
    bool ReloadOnChange { get; set; }
}

ConsulConfigurationSource

该类提供了一个构造函数，用于接收ServiceKey和CancellationToken实例

public ConsulConfigurationSource(string serviceKey, CancellationToken cancellationToken)
{
    if (string.IsNullOrWhiteSpace(serviceKey))
    {
        throw new ArgumentNullException(nameof(serviceKey));
    }
    this.ServiceKey = serviceKey;
    this.CancellationToken = cancellationToken;
}

其build()方法也比较简单，主要是初始化ConsulConfigurationParser实例

public IConfigurationProvider Build(IConfigurationBuilder builder)
{
    ConsulConfigurationParser consulParser = new ConsulConfigurationParser(this);
    return new ConsulConfigurationProvider(this, consulParser);
}

ConsulConfigurationParser

该类比较复杂，主要实现Consul配置的获取、监控以及容错处理，公共方法源码如下

/// <summary>
/// 获取并转换Consul配置信息
/// </summary>
/// <param name="reloading"></param>
/// <param name="source"></param>
/// <returns></returns>
public async Task<IDictionary<string, string>> GetConfig(bool reloading, IConsulConfigurationSource source)
{
    try
    {
        QueryResult<KVPair> kvPair = await this.GetKvPairs(source.ServiceKey, source.QueryOptions, source.CancellationToken).ConfigureAwait(false);
        if ((kvPair?.Response == null) && !source.Optional)
        {
            if (!reloading)
            {
                throw new FormatException(Resources.Error_InvalidService(source.ServiceKey));
            }
            return new Dictionary<string, string>();
        }
        if (kvPair?.Response == null)
        {
            throw new FormatException(Resources.Error_ValueNotExist(source.ServiceKey));
        }
        this.UpdateLastIndex(kvPair);
        return JsonConfigurationFileParser.Parse(source.ServiceKey, new MemoryStream(kvPair.Response.Value));
    }
    catch (Exception exception)
    {
        throw exception;
    }
}

/// <summary>
/// Consul配置信息监控
/// </summary>
/// <param name="key"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public IChangeToken Watch(string key, CancellationToken cancellationToken)
{
    Task.Run(() => this.RefreshForChanges(key, cancellationToken), cancellationToken);
    return this.reloadToken;
}

另外，关于Consul的监控主要利用了QueryResult.LastIndex属性，该类缓存了该属性的值，并与实获取的值进行比较，以判断是否需要重新加载内存中的缓存配置

ConsulConfigurationProvider

该类除了实现Load方法外，还会根据ReloadOnChange属性，在构造函数中注册OnChange事件，用于重新加载配置信息，源码如下：

public sealed class ConsulConfigurationProvider : ConfigurationProvider
{
    private readonly ConsulConfigurationParser configurationParser;
    private readonly IConsulConfigurationSource source;
    public ConsulConfigurationProvider(IConsulConfigurationSource source, ConsulConfigurationParser configurationParser)
    {
        this.configurationParser = configurationParser;
        this.source = source;
        if (source.ReloadOnChange)
        {
            ChangeToken.OnChange(
                () => this.configurationParser.Watch(this.source.ServiceKey, this.source.CancellationToken),
                async () =>
                {
                    await this.configurationParser.GetConfig(true, source).ConfigureAwait(false);
                    Thread.Sleep(source.ReloadDelay);
                    this.OnReload();
                });
        }
    }
    public override void Load()
    {
        try
        {
            this.Data = this.configurationParser.GetConfig(false, this.source).ConfigureAwait(false).GetAwaiter().GetResult();
        }
        catch (AggregateException aggregateException)
        {
            throw aggregateException.InnerException;
        }
    }
}

调用及运行结果

此处调用在Program中实现

public class Program
{
    public static void Main(string[] args)
    {
        CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
WebHost.CreateDefaultBuilder(args).ConfigureAppConfiguration(
            (hostingContext, builder) =>
            {
                builder.AddConsul("userservice", cancellationTokenSource.Token, source =>
                {
                    source.ConsulClientConfiguration = cco => cco.Address = new Uri("http://localhost:8500");
                    source.Optional = true;
                    source.ReloadOnChange = true;
                    source.ReloadDelay = 300;
                    source.QueryOptions = new QueryOptions
                    {
                        WaitIndex = 0
                    };
                });

                builder.AddConsul("commonservice", cancellationTokenSource.Token, source =>
                {
                    source.ConsulClientConfiguration = cco => cco.Address = new Uri("http://localhost:8500");
                    source.Optional = true;
                    source.ReloadOnChange = true;
                    source.ReloadDelay = 300;
                    source.QueryOptions = new QueryOptions
                    {
                        WaitIndex = 0
                    };
                });
            }).UseStartup<Startup>().Build().Run();
    }
}

运行结果，如下图所示，我们已经加载到了两个ConsulProvider实例，这与我们在Program中添加的两个Consul配置一致，其中所加载到的值也和.NET Core Configuration的Key/Value风格相一致，所加载到的值也会Consul中所存储的相一致

总结

基于源码扩展一个配置组件出来，还是比较简单的，另外需要说明的是，该组件关于JSON的处理主要基于.NET Core原生组件，位于命名空间内的System.Text.Json中，所以该组件无法在.NET Core 3.0之前的版本中运行，需要引入额外的JSON组件辅助处理。

GitHub：https://github.com/littlehorse8/Navyblue.Extensions.Configuration.Consul

推荐阅读

（点击标题可跳转阅读）

看完本文有收获？请转发分享给更多人

关注「DotNet」加星标，提升.Net技能 

好文章，我在看❤️